type google.golang.org/grpc.addrConn
27 uses
google.golang.org/grpc (current package)
balancer_wrapper.go#L271: ac *addrConn // read-only
clientconn.go#L188: conns: make(map[*addrConn]struct{}),
clientconn.go#L433: cc.conns = make(map[*addrConn]struct{})
clientconn.go#L697: conns map[*addrConn]struct{} // Set to nil on close.
clientconn.go#L903: func (cc *ClientConn) newAddrConnLocked(addrs []resolver.Address, opts balancer.NewSubConnOptions) (*addrConn, error) {
clientconn.go#L908: ac := &addrConn{
clientconn.go#L939: func (cc *ClientConn) removeAddrConn(ac *addrConn, err error) {
clientconn.go#L982: func (ac *addrConn) connect() {
clientconn.go#L1018: func (ac *addrConn) updateAddrs(addrs []resolver.Address) {
clientconn.go#L1226: go func(ac *addrConn) {
clientconn.go#L1242: type addrConn struct {
clientconn.go#L1279: func (ac *addrConn) updateConnectivityState(s connectivity.State, lastErr error) {
clientconn.go#L1312: func (ac *addrConn) adjustParams(r transport.GoAwayReason) {
clientconn.go#L1326: func (ac *addrConn) resetTransportAndUnlock() {
clientconn.go#L1413: func (ac *addrConn) updateTelemetryLabelsLocked() {
clientconn.go#L1428: func (ac *addrConn) securityLevelLocked() string {
clientconn.go#L1452: func (ac *addrConn) tryAllAddrs(ctx context.Context, addrs []resolver.Address, connectDeadline time.Time) error {
clientconn.go#L1490: func (ac *addrConn) createTransport(ctx context.Context, addr resolver.Address, copts transport.ConnectOptions, connectDeadline time.Time) error {
clientconn.go#L1610: func (ac *addrConn) startHealthCheck(ctx context.Context) {
clientconn.go#L1671: func (ac *addrConn) resetConnectBackoff() {
clientconn.go#L1680: func (ac *addrConn) getReadyTransport() transport.ClientTransport {
clientconn.go#L1693: func (ac *addrConn) tearDown(err error) {
clientconn.go#L1785: func (ac *addrConn) incrCallsStarted() {
clientconn.go#L1790: func (ac *addrConn) incrCallsSucceeded() {
clientconn.go#L1794: func (ac *addrConn) incrCallsFailed() {
stream.go#L1283: func newNonRetryClientStream(ctx context.Context, desc *StreamDesc, method string, t transport.ClientTransport, ac *addrConn, opts ...CallOption) (_ ClientStream, err error) {
stream.go#L1392: ac *addrConn